package com.yanghx.order.server.message;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author yangHX
 * createTime  2019/9/13 22:37
 */
public interface StreamClient {


    String INPUT = "myMessage_input";
    String OUTPUT = "myMessage_output";

    String INPUT2 = "myMessage2_input";
    String OUTPUT2 = "myMessage2_output";

    @Input(StreamClient.INPUT)
    SubscribableChannel input();

    @Output(StreamClient.OUTPUT)
    MessageChannel output();


    @Input(StreamClient.INPUT2)
    SubscribableChannel input2();

    @Output(StreamClient.OUTPUT2)
    MessageChannel output2();
}
